//package com.zhuchang.self_rpc.test.democoding.nettydemo;
//
//import java.util.concurrent.CompletableFuture;
//import java.util.concurrent.CompletionStage;
//import java.util.concurrent.ExecutorService;
//import java.util.concurrent.Executors;
//
///**
// * @Author RenPu
// * @Date 2024/2/3 20:10
// * @Version 1.0
// * @Description:
// **/
//public class TT {
//
//    public static void main(String[] args) {
//        System.out.println("CPu 处理数为：：：："+Runtime.getRuntime().availableProcessors());
//
//                // 创建一个线程池
//                ExecutorService executor = Executors.newFixedThreadPool(1);
//
//                // 提交任务到线程池并返回 Future 对象
//                CompletionStage<String> futureResult = CompletableFuture.supplyAsync(() -> {
//                    try {
//                        Thread.sleep(2000); // 模拟耗时操作
//                    } catch (InterruptedException e) {
//                        e.printStackTrace();
//                    }
//
//                    return "hello CompletableFuture "; // 返回结果
//                }, executor);
//
//                // 设置回调函数处理完成后的操作（非阻塞）
//                futureResult.thenAccept((result) -> System.out.println("异步计算结果为：" + result));
//
//                // 关闭线程池
//                executor.shutdown();
//            }
//
//}
